package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.arithmetic.common.DrivingData;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.SparkSession;

import java.io.Serializable;
import java.util.Date;

/**
 * 行程统计中间结果的服务
 * @author web
 */
public interface DrivingDataService extends Serializable {
    /**
     * 获取昨日的中间数据
     * @param spark
     * @param jsc
     * @param date 当前日期毫秒数
     * @return
     */
    JavaPairRDD<Long,DrivingData> load(SparkSession spark, JavaSparkContext jsc, long date);
    /**
     * 保存中间数据
     * @param spark
     * @param jsc
     * @param pairTidDrivingData
     * @param date
     */
    void save(SparkSession spark, JavaSparkContext jsc, JavaPairRDD<Long, DrivingData> pairTidDrivingData, long date);

}
